package com.qcby.pushservice.web.mq;

import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Service;

@Service
public class TestLister {
    @KafkaListener(topics = "test", groupId = "pushservice-system-web")
    public void consume(String message) {
        System.out.println("Received message: " + message);
    }


}
